14fb1446c655860fd20723f3713ca8ab0d6111a0,foxtrot-core/src/main/java/com/flipkart/foxtrot/core/datastore/impl/hbase/HBaseUtil.java,HBaseUtil,create,#HbaseConfig#,35
Before Change
public static Configuration create(final HbaseConfig hbaseConfig) throws IOException {
Configuration configuration = HBaseConfiguration.create();
if(hbaseConfig.isSecure()
&& null != hbaseConfig.getKeytabFileName()
&& !hbaseConfig.getKeytabFileName().isEmpty()) {
File file = new File(hbaseConfig.getKeytabFileName());
if (file.exists()) {
configuration.addResource(new File(hbaseConfig.getCoreSite()).toURI().toURL());
configuration.addResource(new File(hbaseConfig.getHdfsSite()).toURI().toURL());
configuration.addResource(new File(hbaseConfig.getHbasePolicy()).toURI().toURL());
configuration.addResource(new File(hbaseConfig.getHbaseSite()).toURI().toURL());
configuration.set("hbase.master.kerberos.principal", hbaseConfig.getAuthString());
configuration.set("hadoop.kerberos.kinit.command", hbaseConfig.getKinitPath());
UserGroupInformation.setConfiguration(configuration);
After Change
configuration.addResource(new File(hbaseConfig.getHbasePolicy()).toURI().toURL());
}
if (isValidFile(hbaseConfig.getHbaseSite())) {
configuration.addResource(new File(hbaseConfig.getHbaseSite()).toURI().toURL());
}
if (hbaseConfig.isSecure() && isValidFile(hbaseConfig.getKeytabFileName())) {
configuration.set("hbase.master.kerberos.principal", hbaseConfig.getAuthString());
configuration.set("hadoop.kerberos.kinit.command", hbaseConfig.getKinitPath());
UserGroupInformation.setConfiguration(configuration);